const mysql = require("mysql")
const {mysqlConfig} = require("../utils/config")

const pool = mysql.createPool(mysqlConfig)

// 查询相关
let query = (sql, data) => {
  return new Promise((resolve, reject) => {
    // getConnection 获取连接  回调函数中返回
    // err 连接是否失败
    // conncetion 获取连接的连接信息
    pool.getConnection((err, conncetion) => {
      if (!err) {
        // sql 查询的语句
        // data 查询过程中需要的数据
        // error  查询的错误信息
        // result 查询的结果
        conncetion.query(sql, data, (error, result) => {
          if (!error) {
            // 将查询成功返回的数据转入 resolve 中
            resolve(result)
          } else {
            console.log("数据库查询错误：", err)
            reject(error)
          }
          conncetion.release()
        })
      } else {
        console.log("数据库连接错误：", err)
        reject(err)
      }
    })
  })
}

module.exports = query
